package com.hspedu.qqclient.service;

import com.hspedu.qqcommon.Message;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.Socket;

/**
 * @author DL5O
 * @version 1.0
 */
public class ClientConnectServerThread extends Thread{
    //该线程需要持有Socket
    private Socket socket;

    public ClientConnectServerThread(Socket socket){
        this.socket = socket;
    }

    //
    @Override
    public void run() {
        //因为Thread需要在后台和服务器通讯,因此我们使用while循环来控制
        while(true){
            System.out.println("客服端线程，等待读取从服务器发送的消息....");
            try {
                ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
                //读取一个对象,如果服务器没有发送数据，那么就会阻塞在这里
                Message message = (Message)ois.readObject();

            } catch (IOException | ClassNotFoundException e) {
                e.printStackTrace();
            }
        }
    }

    //为了得到socket，提供socket
    public Socket getSocket() {
        return socket;
    }
}
